package me;

import java.util.concurrent.ArrayBlockingQueue;

public class RecordBuffer {
	
	private ArrayBlockingQueue<Object> queue = new ArrayBlockingQueue<>(1024);
	
	public Object take() throws InterruptedException {
		return queue.take();
	}
	
	public void put(Object entry) throws InterruptedException {
		queue.put(entry);
	}
}
